package com.archgeek.scala.code

/**
 *
 * @author pizhihui
 * @date 2023-12-02 17:06
 */
class LoadListener {


  private val exportHbaseTask: java.util.concurrent.BlockingQueue[CreateBatchRequest] = new java.util.concurrent.ArrayBlockingQueue[CreateBatchRequest](50000)
  private val exportRedisTask: java.util.concurrent.BlockingQueue[CreateBatchRequest] = new java.util.concurrent.ArrayBlockingQueue[CreateBatchRequest](10000)



}
